package com.hexinfo.dmpro.dev.data.transfer.model;

import lombok.Data;

@Data
public class HiveDataExportModel {

    /**
     * HDFS 地址
     */
    private String hdfsUrls;

    /**
     * 本地存储文件根目录
     */
    private String localDir;

    /**
     * HIVE 连接URL
     */
    private String hiveJdbcUrl;

    /**
     * HIVE 登录用户名
     */
    private String hiveUserName;

    /**
     * HIVE 登录密码
     */
    private String hivePassword;

    /**
     * 导出查询SQL
     */
    private String hiveQuerySql;

    /**
     * 库名称
     */
    private String databaseName;

    /**
     * 表名称
     */
    private String tableName;

    /**
     * TXT 文本数据分隔符
     */
    private String separator = "\\001";

    /**
     * 导出文件是否下载到本地
     */
    private String isDownloadToLocal = "N";

    /**
     * 文件传输类型
     */
    private String transferType = "FTP";

    /**
     * FTP 主机
     */
    private String ftpHost;

    /**
     * FTP 端口
     */
    private Integer ftpPort;

    /**
     * FTP 登录用户名
     */
    private String ftpUserName;

    /**
     * FTP 登录密码
     */
    private String ftpPassword;

    /**
     * FTP 远程目录
     */
    private String remoteDir;

    /**
     * 当天日期
     */
    private String currentDate;

    /**
     * 当前时间戳
     */
    private String currentSeconds;

    /**
     * 是否传输到FTP文件服务器
     */
    private String isTransferToFtp = "Y";

    /**
     * 是否生成信号文件
     */
    private String isCreateFlagFile = "N";

    /**
     * 是否对文件进行压缩
     */
    private String isFileCompress = "Y";

    private String createTableSql;

    private String createTxtTableSql;

    private String insertDataSql;

    public String getDbAndTableName() {
        return databaseName + "." + tableName;
    }

}
